LanguageExt.Core ► Effects ► Pipes ► Queue
Contents
- Queue <OUT, M, A>
- Enqueue (OUT value)
- EnqueueM (OUT value)
- Done ()
- DoneM
- ToProxy ()
- Bind <S> (Func<A, Proxy<Void, Unit, Unit, OUT, M, S>> f)
- Map <B> (Func<A, B> f)
- Select <B> (Func<A, B> f)
- For <C1, C> (Func<OUT, Proxy<Void, Unit, C1, C, M, Unit>> body)
- Action <B> (Proxy<Void, Unit, Unit, OUT, M, B> r)
- PairEachRequestWithRespond <UOutA, AUInA> ( Func<Void, Proxy<UOutA, AUInA, Void, Unit, M, A>> lhs)
- ReplaceRequest <UOutA, AUInA> ( Func<Void, Proxy<UOutA, AUInA, Unit, OUT, M, Unit>> lhs)
- PairEachRespondWithRequest <DInC, DOutC> ( Func<OUT, Proxy<Unit, OUT, DInC, DOutC, M, A>> rhs)
- ReplaceRespond <DInC, DOutC> ( Func<OUT, Proxy<Void, Unit, DInC, DOutC, M, Unit>> rhs)
- Reflect ()
- Observe ()
- | (Queue<OUT, M, A> p1, Consumer<OUT, M, A> p2)
- | (Queue<OUT, M, A> p1, Consumer<OUT, A> p2)
- ToString ()
record Queue <OUT, M, A> Source #
Properties
Methods
method Proxy<Void, Unit, Unit, OUT, M, S> Bind <S> (Func<A, Proxy<Void, Unit, Unit, OUT, M, S>> f) Source #
method Proxy<Void, Unit, C1, C, M, A> For <C1, C> (Func<OUT, Proxy<Void, Unit, C1, C, M, Unit>> body) Source #
method Proxy<Void, Unit, Unit, OUT, M, B> Action <B> (Proxy<Void, Unit, Unit, OUT, M, B> r) Source #
method Proxy<UOutA, AUInA, Unit, OUT, M, A> PairEachRequestWithRespond <UOutA, AUInA> ( Func<Void, Proxy<UOutA, AUInA, Void, Unit, M, A>> lhs) Source #
(f +>> p) pairs each 'request' in this with a 'respond' in lhs.
method Proxy<UOutA, AUInA, Unit, OUT, M, A> ReplaceRequest <UOutA, AUInA> ( Func<Void, Proxy<UOutA, AUInA, Unit, OUT, M, Unit>> lhs) Source #
method Proxy<Void, Unit, DInC, DOutC, M, A> PairEachRespondWithRequest <DInC, DOutC> ( Func<OUT, Proxy<Unit, OUT, DInC, DOutC, M, A>> rhs) Source #
method Proxy<Void, Unit, DInC, DOutC, M, A> ReplaceRespond <DInC, DOutC> ( Func<OUT, Proxy<Void, Unit, DInC, DOutC, M, Unit>> rhs) Source #